package com.talent.web.mqtt.handler;

import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

/**
 * @Author: hszhou
 * @Date: 2025/1/8 21:15
 * @Description: 必须描述类做什么事情, 实现什么功能
 */
@MessagingGateway(defaultRequestChannel = "outPutChannel")
public interface MqttGateway {

    void sendToMqtt(@Header(MqttHeaders.TOPIC)String topic,String payload);

    void sendToMqtt(@Header(MqttHeaders.TOPIC)String topic,@Header(MqttHeaders.QOS)int qos,String payload);
}
